#pragma once

#include "zmq.h"
#include <string>
#include "BDZmqBase.h"

class BDZmqReceiver : public BDZmqBase
{
public:
	BDZmqReceiver(std::string address);
	~BDZmqReceiver();

	int Init();

	int DeInit();

	int RecvMsg(void* buffer, unsigned int length);

private:

	void* m_pSocket;

	zmq_pollitem_t m_PollItem;

	std::string m_sAddress;

};

